-
Notifications
You must be signed in to change notification settings - Fork 1.6k
[ENH] Wire up proto defs for sysdb fork endpoint #4299
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Reviewer ChecklistPlease leverage this checklist to ensure your code review is thorough before approving Testing, Bugs, Errors, Logs, Documentation
System Compatibility
Quality
|
if len(segmentpbList) != 3 { | ||
log.Error("GetCollectionWithSegments failed. Unexpected number of collection segments", zap.String("collection_id", collectionID)) | ||
return res, grpcutils.BuildInternalGrpcError(fmt.Sprintf("Unexpected number of segments for collection %s: %d", collectionID, len(segmentpbList))) | ||
} | ||
|
||
scopes := []coordinatorpb.SegmentScope{coordinatorpb.SegmentScope_METADATA, coordinatorpb.SegmentScope_RECORD, coordinatorpb.SegmentScope_VECTOR} | ||
|
||
for _, scope := range scopes { | ||
if _, exists := scopeToSegmentMap[scope]; !exists { | ||
log.Error("GetCollectionWithSegments failed. Collection segment scope not found", zap.String("collection_id", collectionID), zap.String("missing_scope", scope.String())) | ||
return res, grpcutils.BuildInternalGrpcError(fmt.Sprintf("Missing segment scope for collection %s: %s", collectionID, scope.String())) | ||
} | ||
} | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
note: this is removed because the rust frontend performs the same check after receiving the response
This stack of pull requests is managed by Graphite. Learn more about stacking. |
e451d59
to
70a8d27
Compare
70a8d27
to
0e5dcf1
Compare
@@ -59,6 +59,11 @@ type UpdateCollection struct { | |||
Ts types.Timestamp | |||
} | |||
|
|||
type ForkCollection struct { | |||
SourceCollectionID types.UniqueID | |||
TargetCollectionName *string |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: why is this *string
instead of string
? Can it ever be NULL?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It should not be null. Will fix
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fixed
0e5dcf1
to
436d62d
Compare
436d62d
to
8418e8f
Compare
8418e8f
to
077e554
Compare
Merge activity
|
Description of changes
Summarize the changes made by this PR.
table_catalog.go
Test plan
How are these changes tested?
pytest
for python,yarn test
for js,cargo test
for rustDocumentation Changes
Are all docstrings for user-facing APIs updated if required? Do we need to make documentation changes in the docs repository?